RequestHandlerAdaptor

Undocumented in source.

Constructors

this
this(RequestHandler handler)
Undocumented in source.

Members

Functions

detachTransaction
void detachTransaction()
Undocumented in source. Be warned that the author may not have intended to support it.
onBody
void onBody(ubyte[] chain)
Undocumented in source. Be warned that the author may not have intended to support it.
onChunkComplete
void onChunkComplete()
Undocumented in source. Be warned that the author may not have intended to support it.
onChunkHeader
void onChunkHeader(size_t lenght)
Undocumented in source. Be warned that the author may not have intended to support it.
onEOM
void onEOM()
Undocumented in source. Be warned that the author may not have intended to support it.
onEgressPaused
void onEgressPaused()
Undocumented in source. Be warned that the author may not have intended to support it.
onEgressResumed
void onEgressResumed()
Undocumented in source. Be warned that the author may not have intended to support it.
onError
void onError(HTTPErrorCode erromsg)
Undocumented in source. Be warned that the author may not have intended to support it.
onHeadersComplete
void onHeadersComplete(HttpMessage msg)
Undocumented in source. Be warned that the author may not have intended to support it.
onUpgtade
bool onUpgtade(CodecProtocol protocol, HttpMessage msg)
Undocumented in source. Be warned that the author may not have intended to support it.
onWsFrame
void onWsFrame(WSFrame wsf)
Undocumented in source. Be warned that the author may not have intended to support it.
sendBody
void sendBody(ubyte[] data, bool iseom)
Undocumented in source. Be warned that the author may not have intended to support it.
sendChunkHeader
void sendChunkHeader(size_t len)
Undocumented in source. Be warned that the author may not have intended to support it.
sendChunkTerminator
void sendChunkTerminator()
Undocumented in source. Be warned that the author may not have intended to support it.
sendEOM
void sendEOM()
Undocumented in source. Be warned that the author may not have intended to support it.
sendHeaders
void sendHeaders(HttpMessage msg)
Undocumented in source. Be warned that the author may not have intended to support it.
sendHeadersWithEOM
void sendHeadersWithEOM(HttpMessage msg)
Undocumented in source. Be warned that the author may not have intended to support it.
sendTimeOut
void sendTimeOut()
Undocumented in source. Be warned that the author may not have intended to support it.
sendWsData
void sendWsData(OpCode code, ubyte[] data)
Undocumented in source. Be warned that the author may not have intended to support it.
setTransaction
void setTransaction(HTTPTransaction txn)
Undocumented in source. Be warned that the author may not have intended to support it.
socketWrite
void socketWrite(StreamWriteBuffer buffer)
Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From ResponseHandler

sendHeaders
void sendHeaders(HTTPMessage headers)
Undocumented in source.
sendHeadersWithEOM
void sendHeadersWithEOM(HTTPMessage headers)
Undocumented in source.
sendChunkHeader
void sendChunkHeader(size_t len)
Undocumented in source.
sendBody
void sendBody(ubyte[] data, bool iseom)
Undocumented in source.
sendChunkTerminator
void sendChunkTerminator()
Undocumented in source.
sendEOM
void sendEOM()
Undocumented in source.
sendTimeOut
void sendTimeOut()
Undocumented in source.
socketWrite
void socketWrite(ubyte[] data, DataWrittenHandler cback)
Undocumented in source. Be warned that the author may not have intended to support it.
socketWrite
void socketWrite(StreamWriteBuffer buffer)
Undocumented in source.
sendWsData
void sendWsData(OpCode code, ubyte[] data)
Undocumented in source.
_upstream
RequestHandler _upstream;
Undocumented in source.

From HTTPTransactionHandler

setTransaction
void setTransaction(HTTPTransaction txn)

Called once per transaction. This notifies the handler of which transaction it should talk to and will receive callbacks from.

detachTransaction
void detachTransaction()

Called once after a transaction successfully completes. It will be called even if a read or write error happened earlier. This is a terminal callback, which means that the HTTPTransaction object that gives this call will be invalid after this function completes.

onHeadersComplete
void onHeadersComplete(HTTPMessage msg)

Called at most once per transaction. This is usually the first ingress callback. It is possible to get a read error before this however. If you had previously called pauseIngress(), this callback will be delayed until you call resumeIngress().

onBody
void onBody(ubyte[] chain)

Can be called multiple times per transaction. If you had previously called pauseIngress(), this callback will be delayed until you call resumeIngress().

onChunkHeader
void onChunkHeader(size_t length)

Can be called multiple times per transaction. If you had previously called pauseIngress(), this callback will be delayed until you call resumeIngress(). This signifies the beginning of a chunk of length 'length'. You will receive onBody() after this. Also, the length will be greater than zero.

onChunkComplete
void onChunkComplete()

Can be called multiple times per transaction. If you had previously called pauseIngress(), this callback will be delayed until you call resumeIngress(). This signifies the end of a chunk.

onEOM
void onEOM()

Can be called once per transaction. If you had previously called pauseIngress(), this callback will be delayed until you call resumeIngress(). After this callback is received, there will be no more normal ingress callbacks received (onEgress*() and onError() may still be invoked). The Handler should consider ingress complete after receiving this message. This Transaction is still valid, and work may still occur on it until detachTransaction is called.

onError
void onError(HTTPErrorCode erromsg)

Can be called at any time before detachTransaction(). This callback implies that an error has occurred. To determine if ingress or egress is affected, check the direciont on the HTTPException. If the direction is INGRESS, it MAY still be possible to send egress.

onEgressPaused
void onEgressPaused()

If the remote side's receive buffer fills up, this callback will be invoked so you can attempt to stop sending to the remote side.

onEgressResumed
void onEgressResumed()

This callback lets you know that the remote side has resumed reading and you can now continue to send data.

onWsFrame
void onWsFrame(WSFrame wsf)
Undocumented in source.
onUpgtade
bool onUpgtade(CodecProtocol protocol, HTTPMessage msg)
Undocumented in source.

Meta